"""
@Author  : 康帅
@Time    : 2021/5/26 11:18
@Function: Python redis Hash使用
"""

import redis

#  使用连接池连接，避免每次建立、释放连接的开销
# redis 取出的结果默认是字节，我们可以设定 decode_responses=True 改成字符串
pool = redis.ConnectionPool(host='127.0.0.1', port=6379, decode_responses=True)
r = redis.Redis(connection_pool=pool)

"""单个增加--修改(单个取出)--没有就新增，有的话就修改
hset(name, key, value)
name - redis的name
key - name对应的hash中的key
value - name对应的hash中的value"""
r.hset("hash1", "k1", "v1")
r.hset("hash1", "k2", "v2")
print(r.hkeys("hash1"))  # 取hash中所有的key
print(r.hget("hash1", "k1"))  # 单个取hash的key对应的值
print(r.hmget("hash1", "k1", "k2"))  # 多个取hash的key对应的值

"""hsetnx(name, key, value) 当name对应的hash中不存在当前key时则创建（相当于添加）"""
r.hsetnx("hash1", "k2", "v3")  # 只能新建
print(r.hget("hash1", "k2"))

"""批量增加（取出）
hmset(name, mapping)
name - redis的name
mapping - 字典，如：{'k1':'v1', 'k2': 'v2'}"""
r.hmset('hash2', {"k2": "v2", "k3": "v3"})
print(r.hget('hash2', 'k2'))

"""在name对应的hash中获取根据key获取value
hmget(name, keys, *args)
name - reids对应的name
keys - 要获取key集合，如：['k1', 'k2', 'k3']
*args - 要获取的key，如：k1,k2,k3"""
print(r.hget("hash2", "k2"))  # 单个取出"hash2"的key-k2对应的value
print(r.hmget("hash2", "k2", "k3"))  # 批量取出"hash2"的key-k2 k3对应的value --方式1
print(r.hmget("hash2", ["k2", "k3"]))  # 批量取出"hash2"的key-k2 k3对应的value --方式2

"""取出所有的键值对
hgetall(name)"""
print(r.hgetall("hash1"))

"""得到所有键值对的格式hash长度
hlen(name)"""
print(r.hlen("hash1"))

"""得到所有的keys（类似字典的取所有keys）
hkeys(name)"""
print(r.hkeys('hash1'))

"""得到所有的value（类似字典的取所有value）
hvals(name)"""
print(r.hvals('hash2'))

"""判断成员是否存在（类似字典的in）
hexists(name, key)"""
print(r.hexists('hash1', 'k4'))

"""删除键值对
hdel(name,*keys)"""
# r.hdel('hash2', "k2")
print(r.hgetall('hash2'))

"""自增自减整数(将key对应的value--整数 自增1或者2，或者别的整数 负数就是自减)
hincrby(name, key, amount=1)
name - redis中的name
key - hash对应的key
amount - 自增数（整数）
自增name对应的hash中的指定key的值，不存在则创建key=amount"""
r.hset("hash1", "k3", 123)
r.hincrby("hash1", "k3", amount=-1)
print(r.hgetall("hash1"))
r.hincrby("hash1", "k4", amount=1)  # 不存在的话，value默认就是1
print(r.hgetall("hash1"))

"""自增自减浮点数(将key对应的value--浮点数 自增1.0或者2.0，或者别的浮点数 负数就是自减)
hincrbyfloat(name, key, amount=1.0)
name - redis中的name
key - hash对应的key
amount，自增数（浮点数）
自增 name 对应的 hash 中的指定 key 的值，不存在则创建 key=amount"""
r.hset("hash1", "k5", "1.0")
r.hincrbyfloat("hash1", "k5", amount=-1.0)  # 已经存在，递减-1.0
print(r.hgetall("hash1"))
r.hincrbyfloat("hash1", "k6", amount=-1.0)  # 不存在，value初始值是-1.0 每次递减1.0
print(r.hgetall("hash1"))

"""取值查看--分片读取
hscan(name, cursor=0, match=None, count=None)
增量式迭代获取，对于数据大的数据非常有用，hscan可以实现分片的获取数据，并非一次性将数据全部获取完，从而放置内存被撑爆
name - redis的name
cursor - 游标（基于游标分批取获取数据）
match - 匹配指定key，默认None 表示所有的key
count - 每次分片最少获取个数，默认None表示采用Redis的默认分片个数
直到返回值cursor的值为0时，表示数据已经通过分片获取完毕
"""
print(r.hscan("hash1"))

"""hscan_iter(name, match=None, count=None)
利用yield封装hscan创建生成器，实现分批去redis中获取数据
match - 匹配指定key，默认None 表示所有的key
count - 每次分片最少获取个数，默认None表示采用Redis的默认分片个数
"""
for item in r.hscan_iter('hash1'):
    print(item)
print(r.hscan_iter("hash1"))  # 生成器内存地址
